package com.jeffse.light.stream.core.function.base;

import com.jeffse.light.stream.core.data.context.Context;

@FunctionalInterface
public interface SinkFunction<T, V> extends Function {

    void run(T value, Context ctx) throws Exception;

}
